Micron Document
welo git mirrors

Node / public / rns-proxy / commits / 19b3535

Commit 19b3535f7a5e19431ede0b7656f1b223a6cf4ecc

🗀 Browse tree at this commit

Parents : 44e5bd3
Author : welo | main nixos computer <empty@empty.com>
Date : 2026-07-04T09:55:43+01:00

added proper udp forwarding; i think

Changes

2 files changed, 25 insertions(+), 20 deletions(-)

M src/relay.rs +24 -8
M src/server.rs +1 -12

Diff

diff --git a/src/relay.rs b/src/relay.rs
index 7473946..5187cca 100644
--- a/src/relay.rs
+++ b/src/relay.rs
@@ -3,8 +3,11 @@
use std::sync::Arc;
use std::time::Duration;
+use fast_socks5::parse_udp_request;
+use fast_socks5::util::target_addr::{TargetAddr, ToTargetAddr};
use log::{debug, warn};
use tokio::io::{AsyncReadExt, AsyncWriteExt};
+use tokio::net::unix::SocketAddr;
use tokio::sync::mpsc;
use crate::frame::{Frame, FrameType};
@@ -101,7 +104,7 @@ pub async fn relay_bidirectional_udp(
mux_fwd.send(FrameType::Data, sid, buf[..n].to_vec());
}
Err(e) => {
- debug!("[{}] TCP read error: {}", sid, e);
+ debug!("[{}] UDP read error: {}", sid, e);
break;
}
}
@@ -113,13 +116,26 @@ pub async fn relay_bidirectional_udp(
while let Some(frame) = session_rx.recv().await {
match frame.frame_type {
FrameType::Data => {
- println!("sending rns to udp data {:?}", frame);
- println!("sending rns to udp data {:?}", String::from_utf8_lossy(&*frame.payload));
- println!("sending from: {:?} to {:?}", socket1.local_addr(), socket1.peer_addr());
- if let Err(e) = socket1.send(&frame.payload).await {
- warn!("[{}] TCP write error: {}", sid, e);
- break;
- }
+ match parse_udp_request(&*frame.payload).await {
+ Ok((frag,addr,data)) => {
+ println!("sending rns to udp data {:?}:{:?}:{:?}", frame, addr, data);
+ println!("sending rns to udp data {:?}", String::from_utf8_lossy(data));
+ println!("sending from: {:?} to {:?}", socket1.local_addr(), socket1.peer_addr());
+
+ let target = addr.into_string_and_port(); // string conversion is the only way to convert
+ // between the tokio and fastsocksv5 versions for some reason
+
+ if let Err(e) = socket1.send_to(data,target).await {
+ warn!("[{}] UDP write error: {}", sid, e);
+ break;
+ }
+ }
+ Err(e) => {
+
+ }
+
+ };
+
}
FrameType::Close => break,
_ => {}

diff --git a/src/server.rs b/src/server.rs
index 6b081b6..6685c2f 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -251,18 +251,6 @@ async fn handle_server_session_udp(
};
- info!("{:?}", format!("{}:{}", host, port));
- let destination = "dns.google:53";
- match socket.connect(destination).await {
- Ok(s) => s,
- Err(e) => {
- warn!("[{}] udp connection failed 2: {}", sid, e);
- mux.send(FrameType::ConnectErr, sid, e.to_string().into_bytes());
- mux.drop_session(sid);
- return;
- }
- };
-
info!("successfully made connection?");
// Signal success
mux.send(FrameType::ConnectOk, sid, Vec::new());
@@ -271,3 +259,4 @@ async fn handle_server_session_udp(
relay_bidirectional_udp(sid, socket, None, mux, session_rx).await;
info!("[{}] Closed", sid);
}
+

Served by rngit 1.4.2 - Generated in 0.03s